package com.deng.eventflow.core.exception;

import com.deng.eventflow.core.Processor;

public class ConnectorException extends RuntimeException{
    /**
     * Dummy UID
     */
    private static final long serialVersionUID = 1L;

    /**
     * The processor at the source of the connection
     */
    protected final transient Processor m_source;

    /**
     * The processor at the destination of the connection
     */
    protected final transient Processor m_destination;

    /**
     * The index of the stream in the source processor
     */
    protected final int m_sourceIndex;

    /**
     * The index of the stream in the destination processor
     */
    protected final int m_destinationIndex;

    ConnectorException(Processor source, Processor destination, int i, int j)
    {
        super();
        m_source = source;
        m_destination = destination;
        m_sourceIndex = i;
        m_destinationIndex = j;
    }

}
